package com.yujinglin.airline;

import org.apache.hadoop.io.IntWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Partitioner;

import java.util.regex.Matcher;
import java.util.regex.Pattern;

public class airlinePartitioner extends Partitioner<IntWritable,airlineWritable> {
    @Override
    public int getPartition(IntWritable key, airlineWritable airlineWritable, int i) {

        return key.get()/1500;

    }
}
